package com.learn.demo1;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;

/**
 * Created by 郑靖 on 2017/9/20.
 */
@EnableBinding(SimpleProcessor.class)
public class SimpleDemo {

    @StreamListener(SimpleProcessor.INPUT_NAME)
    public void receiver(Message<String> message) {
        System.err.println("input :" + message.getPayload());
    }


}
